package com.jt.demos;

import redis.clients.jedis.Jedis;

import java.util.Set;

/*
 投票系统
 */
public class VoteDemo {

    //注意,将来这个连接不能多线程共享
    private  static  Jedis jedis = new Jedis("192.168.126.128", 6379);

    public static void main(String[] args) {


        //0.初始化
        String activityId="10001";
        String user1="201";
        String user2="202";
        String user3="203";

        //1.检查用户是否投过票
        boolean flag=checkVote(activityId,user1);
        System.out.println(user1+":"+(flag?"已投过票":"还没投票"));//201:还没投票

        //2.投票
        vote(activityId,user1);
        vote(activityId,user2);
        vote(activityId,user3);

        //3.获取投票次数
        Long voteCount = getVoteCount(activityId);
        System.out.println("投票次数:"+voteCount);//投票次数:3
        //4.参与投票的用户id【管理员查看】
        Set<String> users=getVoteUsers(activityId);
        System.out.println(users);//[201, 202, 203]



    }
    //获取并查看参与投票的用户id信息
    private static Set<String> getVoteUsers(String activityId) {
        Set<String> smembers = jedis.smembers(activityId);
        return smembers;
    }

    //检查此用户是否已参与过投票
    private static boolean checkVote(String activityId, String userId) {
        Boolean flag = jedis.sismember(activityId, userId);
        return flag;
    }


    //查看投票次数【投票总数】
    private static Long getVoteCount(String activityId) {
        Long count = jedis.scard(activityId);
        return count;
    }

    //进行投票(key为活动id,value为userId)【投票逻辑】
    private static boolean vote(String activityId,String userId) {
        if(checkVote(activityId,userId)){
            System.out.println("您已经参与过这个投票");
            return false;
        }
        jedis.sadd(activityId,userId);
        return true;
    }

}
